package com.azdebugit.processor.test;

import com.lmax.disruptor.EventHandler;

/**
 * 订单回调事件消费 - 开放平台通知
 *
 * @version OpenNotifiyHandle.java, v 0.1 2018-12-25 21:53
 */
public class OpenNotifiyHandle implements EventHandler<OrderCallBackEvent> {

    @Override
    public void onEvent(OrderCallBackEvent event, long sequence, boolean endOfBatch) throws Exception {
        String orderSn = event.getOrderSn();
        System.out.println("当前线程：" + Thread.currentThread().getName() + " ,OpenNotifiyHandle == orderSn:" +orderSn + " ,sequence:" + sequence + " ,endOfBatch:" + endOfBatch);
    }
}